3962ca62fe3cdec2c860084f50c086d6a8eb6518,rxnetty-examples/src/test/java/io/reactivex/netty/examples/http/helloworld/HelloWorldTest.java,HelloWorldTest,testRequestReplySequence,#,52

Before Change


    @Test
    public void testRequestReplySequence() throws InterruptedException, ExecutionException, TimeoutException {
        HelloWorldClient client = new HelloWorldClient(DEFAULT_PORT);
        HttpResponseStatus statusCode = client.sendHelloRequest().getStatus();
        Assert.assertEquals(HttpResponseStatus.OK, statusCode);
    }
}

After Change


    @Test
    public void testRequestReplySequence() throws InterruptedException, ExecutionException, TimeoutException {
        HelloWorldClient client = new HelloWorldClient(DEFAULT_PORT);
        String response = client.sendHelloRequest();
        Assert.assertEquals("Hello World!", response);
    }
}